package com.storm.lesson.transaction1;

import java.io.Serializable;

/**
 * metadata(元数据)中包含当前事务可以从哪个point进行重放数据，存放在zookeeper中的，spout可以通过Kryo从zookeeper中序列化和反序列化该元数据。
 * @author zhihu
 *
 */
public class MyMata implements Serializable {

	private static final long serialVersionUID = 1L;

	private long beginPoint;// 事务开始位置

	private int num;// batch 的tuple个数

	@Override
	public String toString() {
		return getBeginPoint() + "----------" + getNum();
	}

	public long getBeginPoint() {
		return beginPoint;
	}

	public void setBeginPoint(long beginPoint) {
		this.beginPoint = beginPoint;
	}

	public int getNum() {
		return num;
	}

	public void setNum(int num) {
		this.num = num;
	}

}
